

package org.pizza.rocket.core.listener;


import java.util.List;

/**
 * @author 高巍
 * email kynb_club@163.com
 * @since 2020/11/23 3:36 下午
 * 批量消息监听器
 */
public interface BatchRocketMQListener<T> {
    /**
     * 消息消费回调函数
     * @param messageList 消息
     */
    void onMessage(List<T> messageList);
    /**
     * 消费异常回调函数
     * @param messageList
     * @param e
     */
    default void onError(List<T> messageList, Exception e){};

}
